package com.shujia.base;

import java.io.File;
import java.util.Arrays;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/*
    每个block块会产生一个map任务，每个map任务是一个线程，多个map线程同时执行
    需要写一个多线程，使用之前学过的线程池
 */
public class MapTaskDemo {
    public static void main(String[] args) {
        //创建线程池对象
        ExecutorService pool = Executors.newFixedThreadPool(8);

        //获取所有的block块
        File file = new File("hadoop/data/blocks");
        File[] blocks = file.listFiles();
        //断言
//        assert blocks!=null;

        if(blocks!=null){
            for (File block : blocks) {
                pool.submit(new MapTask(block,block.getName()));
            }
        }

        pool.shutdown();
    }
}